//
//package com.hd.determine.config.mqtt.consumer;
//
//import com.alibaba.fastjson.JSON;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.messaging.Message;
//import org.springframework.messaging.MessageHandler;
//import org.springframework.messaging.MessagingException;
//import org.springframework.stereotype.Component;
//
///**
// * @author chentl
// * @version V1.0
// * @Project 交通运输第三方监测平台
// * @Title GpsConsumer.java
// * @Description gps轨迹数据消费者
// * @Package com.hd.sup.config.mqtt.consumer
// * @date 2021/1/5 3:42 下午
// * @Copyright: 深圳市宏电技术股份有限公司 All rights reserved.
// */
//@Slf4j
//@Component
//public class GpsConsumer implements MessageHandler {
//
//    @Override
//    public void handleMessage(Message<?> message) throws MessagingException {
//        try {
//            //转发
//            String msg = message.getPayload().toString();
//            log.info("[mqtt] 客户端收到消息: {}", JSON.toJSONString(msg));
////            rabbitProducer.sendToGpsDataQueue(msg);
//        } catch (Exception e) {
//            log.error("MQTT 队列发生异常,异常原始消息:{}", message.getPayload());
//        }
//    }
//}
